package com.ruoyi.handle;//package com.ruoyi.demo.handle;

import com.ruoyi.mqtt.annotation.MqttService;
import com.ruoyi.mqtt.annotation.MqttTopic;
import lombok.extern.slf4j.Slf4j;
import org.springframework.messaging.Message;

/**
 * MqttTopicHandle
 *
 * @author 曾午
 * @date 2023/05/10
 */
@MqttService
@Slf4j
public class MqttTopicHandle {

    // 注意 你必须先订阅
    @MqttTopic("aaa/2")
    public void aaa(Message<?> message) {
        log.info("aaa=" + message.getPayload());
    }

    // 注意 你必须先订阅
    @MqttTopic("bbb/2")
    public void bbb(Message<?> message) {
        log.info("bbb=" + message.getPayload());
    }

    // 这里的 # 号是通配符
    @MqttTopic("test/#")
    public void test(Message<?> message) {
        log.info("test=" + message.getPayload());
    }

    // 这里的 + 号是通配符
    @MqttTopic("topic/+/+/up")
    public void up(Message<?> message) {
        log.info("up=" + message.getPayload());
    }

    // 注意 你必须先订阅
    @MqttTopic("topic/1/2/down")
    public void down(Message<?> message) {
        log.info("down=" + message.getPayload());
    }

}
